package com.zhl.spark.core.rddtransform

import com.zhl.spark.core.BasicRdd

/**
 * @program: demos
 * @description: ${description}
 * @author: 刘振华
 * @create: 2020-12-02 17:39
 **/
object TransRdd extends BasicRdd {
    def main(args: Array[String]): Unit = {
        test()
    }

    override def logic(): Unit = {
//        def myMap(num:Int):Int={
//            num * 2
//        }
//        sc.parallelize(List(1,2,3,4)).map(myMap).foreach(println)
//        sc.parallelize(List(1,2,3,4)).map(n=>{n*2}).foreach(println)
//        sc.parallelize(List(1,2,3,4)).map(_*2).foreach(println)
    }
}
